package com.hd.sup.config.rabbitmq.producer;

import com.hd.sup.config.rabbitmq.MqQueueConstant;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * @author chentl
 * @version V1.0
 * @Project 交通运输第三方监测平台
 * @Title RabbitProducer.java
 * @Description rabbitmq 生产者
 * @Package com.hd.determine.config.rabbitmq.producer
 * @date 2021/1/6 3:36 下午
 * @Copyright: 深圳市宏电技术股份有限公司 All rights reserved.
 */
@Slf4j
@Service
public class RabbitProducer {

    @Resource
    private AmqpTemplate rabbitTemplate;

    /**
     * @return void
     * @author chentl
     * @description 发送到报警详情队列
     * @date 2021/1/6 3:53 下午
     * @params [alarmDetail]
     */
    public void sendToStaticDataSyncQueue(String vehicleData) {
        rabbitTemplate.convertAndSend(MqQueueConstant.STATIC_DATA_SYNC_QUEUE, vehicleData.getBytes());
    }

    /**
     * @return void
     * @author chentl
     * @description 发送到分析报告处理队列
     * @date 2021/3/2 9:03 上午
     * @params [reportId]
     */
    public void sendToReportDataGenQueue(String reportId) {
        rabbitTemplate.convertAndSend(MqQueueConstant.REPORT_DATA_GEN_QUEUE, reportId.getBytes());
    }


}
